package sam.learn.demo.kafka;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;


@Component
public class KafkaConsumer {


    protected final Logger logger = LoggerFactory.getLogger(this.getClass());

    @KafkaListener(topics = {"notice"})
    public void listen(ConsumerRecord<?, ?> record) {
        logger.info("kafka的key: {}", record.key());
        logger.info("kafka的value: {}", record.value().toString());
    }

}
